package grpc

func HeartBeat(server *Server) {
	api := server.AddApi("HeartBeat").
		AddDescribe("心跳接口，接收时间戳，原样返回")

	api.AddIn("now").IsInt().
		SetDescribe("接收时间戳，秒级")
	api.AddOut("now").IsInt().
		SetDescribe("原样返回")
}

func BroadcastListen(server *Server) {

	api := server.AddApi("BroadcastListen").
		AddDescribe("注册一个广播服务的监听方，CTL接受到有效的事件是，通过调用本模块的grpc接口将消息转发过来")

	api.AddIn("key").
		IsString().
		SetDescribe("事件的key,详细的约定还没有定出来，需要跟模块挂钩")
	//消息内容可以考虑定义一个通用的结构体来做解析//todo
	api.AddIn("content").
		IsString().
		SetDescribe("通知内容，以JSON字符串的形式传递数据")

	api.AddOut("code").
		IsInt().
		SetDescribe("CTL返回码，参照HTTP Code格式正确返回200，错误返回400 或者 5000")
	api.AddOut("message").
		IsString().
		SetDescribe("返回消息，对代码CODE默认含义进行解释和补充")

}
